3aed140a1572c5aa42da58de6088579fd75ee650,src/test/java/org/gaul/s3proxy/S3AwsSdkTest.java,S3AwsSdkTest,testBigMultipartUpload,#,315
Before Change
(int) byteSource1.size());
UploadPartResult uploadPartResult1 = client.uploadPart(uploadRequest1);
PartETag partETag1 = uploadPartResult1.getPartETag();
ByteSource byteSource2 = byteSource.slice(partSize, size - partSize);
UploadPartRequest uploadRequest2 = new UploadPartRequest()
.withBucketName(containerName).withKey(key)
.withUploadId(uploadId).withPartNumber(2)
.withInputStream(byteSource2.openStream())
.withPartSize(byteSource2.size());
uploadRequest2.getRequestClientOptions().setReadLimit(
(int) byteSource2.size());
UploadPartResult uploadPartResult2 = client.uploadPart(uploadRequest2);
PartETag partETag2 = uploadPartResult2.getPartETag();
// must be mutable since AWK SDK sorts parts
List<PartETag> partETagList = new ArrayList<PartETag>();
partETagList.add(partETag1);
partETagList.add(partETag2);
CompleteMultipartUploadRequest completeRequest = new
After Change
new CompleteMultipartUploadRequest(
containerName, key, uploadId,
ImmutableList.of(
uploadPartResult1.getPartETag(),
uploadPartResult2.getPartETag()));
client.completeMultipartUpload(completeRequest);